4996d8ffd8fe9cd56751b2daba076fe87e6220a3,fess-crawler-es/src/main/java/org/codelibs/fess/crawler/service/impl/EsUrlQueueService.java,EsUrlQueueService,updateSessionId,#String#String#,83

Before Change


    @Override
    public void updateSessionId(final String oldSessionId, final String newSessionId) {
        SearchResponse response =
                ActionGetUtil.actionGet(getClient().prepareSearch(index).setTypes(type).setSearchType(SearchType.SCAN).setScroll(new TimeValue(scrollTimeout))
                    .setQuery(QueryBuilders.boolQuery().filter(QueryBuilders.termQuery(SESSION_ID, oldSessionId))).setSize(scrollSize)
                    .execute());
        while (true) {
            response =
                    ActionGetUtil.actionGet(getClient().prepareSearchScroll(response.getScrollId()).setScroll(new TimeValue(scrollTimeout)).execute());

            final SearchHits searchHits = response.getHits();
            if (searchHits.hits().length == 0) {

After Change


    @Override
    public void updateSessionId(final String oldSessionId, final String newSessionId) {
        SearchResponse response = getClient()
                .get(c -> c.prepareSearch(index).setTypes(type).setSearchType(SearchType.SCAN).setScroll(new TimeValue(scrollTimeout))
                        .setQuery(QueryBuilders.boolQuery().filter(QueryBuilders.termQuery(SESSION_ID, oldSessionId))).setSize(scrollSize)
                        .execute());
        while (true) {
            final SearchResponse prevResponse = response;
            response = getClient()